package service

import (
	"context"
	v1 "goTrain/go-training/stream-producer/api/signal/service/v1"
)

func (s *SignalService)AddStream(ctx context.Context, req *v1.AddStreamReq) (*v1.AddStreamReply, error) {
	return &v1.AddStreamReply{}, nil
}

func (s *SignalService)DeleteStream(ctx context.Context, req *v1.DeleteStreamReq) (*v1.DeleteStreamReply, error) {
	return &v1.DeleteStreamReply{}, nil
}

func (s *SignalService)ConfigStream(ctx context.Context, req *v1.ConfigStreamReq) (*v1.ConfigStreamReply, error) {
	return &v1.ConfigStreamReply{}, nil
}

